b12d4209b522f410293b83f2b789ae6f4173c2b4,tests/junit/org/jgroups/blocks/MuxRpcDispatcherTest.java,MuxRpcDispatcherTest,testMulticastRPCs,#,67

Before Change


        // Validate restarted mux dispatcher functions normally
        muxDispatchers[1][0].start();
        
        responses = muxDispatchers[0][0].callRemoteMethods(null, method, RequestOptions.SYNC().setRspFilter(null));

        Assert.assertEquals(responses.size(), 2);
        verifyResponse(responses, channels[0], "muxDispatcher[0][0]");

After Change


        verifyResponse(responses, channels[1], null);
        
        // Validate stopped mux dispatcher response is auto-filtered and custom filter is applied
        responses = muxDispatchers[0][0].callRemoteMethods(null,method,RequestOptions.SYNC().setTimeout(2000).setRspFilter(filter));

        Assert.assertEquals(responses.size(), 2);
        verifyResponse(responses, channels[0], null);